import java.sql.SQLException;

import oracle.jdbc.aq.AQAgent;
import oracle.jdbc.aq.AQFactory;
import oracle.jdbc.driver.OracleConnection;
import oracle.jdbc.oracore.OracleType;


public class AQTest {

	public AQTest() {
	}
	
	
	public static void main( String[] argv) throws SQLException {
		
		AQEnqueue ae = new AQEnqueue( "strmadmin", "streams", "192.168.0.98", "1521", "bizteco");
		
		OracleConnection conn = ae.connect();
		
	}	

}
